<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1">
    <title>珠峰架构师成长计划</title>
    <link rel="stylesheet" type="text/css" href="../static/css/main.css">
</head>
<body>
<div class="nav">
    <div class="logo">
        
            珠峰架构师成长计划
        
    </div>
<ul><li><a href="../index.html">0.Async</a></li><li><a href="../html/0.editor.html">0.editor</a></li><li><a href="../html/0.module.html">0.module</a></li><li><a href="../html/1.ES2015.html">1.ES2015</a></li><li><a href="../html/2.Promise.html">2.Promise</a></li><li><a href="../html/3.Node.html">3.Node</a></li><li><a href="../html/4.NodeInstall.html">4.NodeInstall</a></li><li><a href="../html/5.REPL.html">5.REPL</a></li><li><a href="../html/6.NodeCore.html">6.NodeCore</a></li><li><a href="../html/7.module&NPM.html">7.module&NPM</a></li><li><a href="../html/8.Encoding.html">8.Encoding</a></li><li><a href="../html/9.Buffer.html">9.Buffer</a></li><li><a href="../html/10.fs.html">10.fs</a></li><li><a href="../html/11.Stream-1.html">11.Stream-1</a></li><li class="active"><a href="../html/11.Stream-2.html">11.Stream-2</a></li><li><a href="../html/11.Stream-3.html">11.Stream-3</a></li><li><a href="../html/11.Stream-4.html">11.Stream-4</a></li><li><a href="../html/12-Network-2.html">12-Network-2</a></li><li><a href="../html/12.NetWork-3.html">12.NetWork-3</a></li><li><a href="../html/12.Network-1.html">12.Network-1</a></li><li><a href="../html/13.tcp.html">13.tcp</a></li><li><a href="../html/14.http-1.html">14.http-1</a></li><li><a href="../html/14.http-2.html">14.http-2</a></li><li><a href="../html/15.compress.html">15.compress</a></li><li><a href="../html/16.crypto.html">16.crypto</a></li><li><a href="../html/17.process.html">17.process</a></li><li><a href="../html/18.yargs.html">18.yargs</a></li><li><a href="../html/19.cache.html">19.cache</a></li><li><a href="../html/20.action.html">20.action</a></li><li><a href="../html/21.https.html">21.https</a></li><li><a href="../html/22.cookie.html">22.cookie</a></li><li><a href="../html/23.session.html">23.session</a></li><li><a href="../html/24.express-1.html">24.express-1</a></li><li><a href="../html/24.express-2.html">24.express-2</a></li><li><a href="../html/24.express-3.html">24.express-3</a></li><li><a href="../html/24.express-4.html">24.express-4</a></li><li><a href="../html/25.koa-1.html">25.koa-1</a></li><li><a href="../html/26.webpack-1-basic.html">26.webpack-1-basic</a></li><li><a href="../html/26.webpack-2-optimize.html">26.webpack-2-optimize</a></li><li><a href="../html/26.webpack-3.tapable.html">26.webpack-3.tapable</a></li><li><a href="../html/26.webpack-4-AST.html">26.webpack-4-AST</a></li><li><a href="../html/26.webpack-5-source.html">26.webpack-5-source</a></li><li><a href="../html/26.webpack-6-loader.html">26.webpack-6-loader</a></li><li><a href="../html/26.webpack-7-plugin.html">26.webpack-7-plugin</a></li><li><a href="../html/26.webpack-8-hand.html">26.webpack-8-hand</a></li><li><a href="../html/27.react-1.html">27.react-1</a></li><li><a href="../html/27.react-2.html">27.react-2</a></li><li><a href="../html/27.react-3.html">27.react-3</a></li><li><a href="../html/27.react-4-immutable.html">27.react-4-immutable</a></li><li><a href="../html/27.react-5-react-dom-diff.html">27.react-5-react-dom-diff</a></li><li><a href="../html/27.react-6.html">27.react-6</a></li><li><a href="../html/28.react-mobx.html">28.react-mobx</a></li><li><a href="../html/28.redux-0.html">28.redux-0</a></li><li><a href="../html/28.redux-1.html">28.redux-1</a></li><li><a href="../html/28.redux-2-中间件.html">28.redux-2-中间件</a></li><li><a href="../html/28.redux-3-saga.html">28.redux-3-saga</a></li><li><a href="../html/28.redux-jwt-back.html">28.redux-jwt-back</a></li><li><a href="../html/28.redux-jwt-front.html">28.redux-jwt-front</a></li><li><a href="../html/29.mongodb-1.html">29.mongodb-1</a></li><li><a href="../html/29.mongodb-2.html">29.mongodb-2</a></li><li><a href="../html/29.mongodb-3.html">29.mongodb-3</a></li><li><a href="../html/29.mongodb-4.html">29.mongodb-4</a></li><li><a href="../html/29.mongodb-5.html">29.mongodb-5</a></li><li><a href="../html/29.mongodb-6.html">29.mongodb-6</a></li><li><a href="../html/30.cms-1-mysql.html">30.cms-1-mysql</a></li><li><a href="../html/30.cms-2-mysql.html">30.cms-2-mysql</a></li><li><a href="../html/30.cms-3-mysql.html">30.cms-3-mysql</a></li><li><a href="../html/30.cms-4-egg.html">30.cms-4-egg</a></li><li><a href="../html/30.cms-5-api.html">30.cms-5-api</a></li><li><a href="../html/30.cms-6-roadhog.html">30.cms-6-roadhog</a></li><li><a href="../html/30.cms-7-umi.html">30.cms-7-umi</a></li><li><a href="../html/30.cms-8-dva.html">30.cms-8-dva</a></li><li><a href="../html/30.cms-9-dva.html">30.cms-9-dva</a></li><li><a href="../html/30.cms-10-front.html">30.cms-10-front</a></li><li><a href="../html/30.cms-11-deploy.html">30.cms-11-deploy</a></li><li><a href="../html/33.redis.html">33.redis</a></li><li><a href="../html/34.unittest.html">34.unittest</a></li><li><a href="../html/35.jwt.html">35.jwt</a></li><li><a href="../html/36.websocket-1.html">36.websocket-1</a></li><li><a href="../html/36.websocket-2.html">36.websocket-2</a></li><li><a href="../html/38.chat-api-1.html">38.chat-api-1</a></li><li><a href="../html/38.chat-api-2.html">38.chat-api-2</a></li><li><a href="../html/38.chat-3.html">38.chat-3</a></li><li><a href="../html/38.chat-api-3.html">38.chat-api-3</a></li><li><a href="../html/38.chat.html">38.chat</a></li><li><a href="../html/38.chat2.html">38.chat2</a></li><li><a href="../html/38.chat2.html">38.chat2</a></li><li><a href="../html/39.crawl-0.html">39.crawl-0</a></li><li><a href="../html/39.crawl-1.html">39.crawl-1</a></li><li><a href="../html/39.crawl-2.html">39.crawl-2</a></li><li><a href="../html/40.deploy.html">40.deploy</a></li><li><a href="../html/41.safe.html">41.safe</a></li><li><a href="../html/42.test.html">42.test</a></li><li><a href="../html/43.nginx.html">43.nginx</a></li><li><a href="../html/44.enzyme.html">44.enzyme</a></li><li><a href="../html/45.docker.html">45.docker</a></li><li><a href="../html/46.elastic.html">46.elastic</a></li><li><a href="../html/47.oauth.html">47.oauth</a></li><li><a href="../html/48.wxpay.html">48.wxpay</a></li><li><a href="../html/49.nunjucks.html">49.nunjucks</a></li><li><a href="../html/50.ketang.html">50.ketang</a></li><li><a href="../html/index.html">index</a></li><li><a href="../html/51.typescript.html">51.typescript</a></li><li><a href="../html/52.UML.html">52.UML</a></li><li><a href="../html/53.design.html">53.design</a></li><li><a href="../html/index.html">index</a></li><li><a href="../html/54.linux.html">54.linux</a></li><li><a href="../html/55.yaml.html">55.yaml</a></li><li><a href="../html/50.ketang2.html">50.ketang2</a></li><li><a href="../html/56.ts.html">56.ts</a></li><li><a href="../html/57.ts_react.html">57.ts_react</a></li><li><a href="../html/58.react-ssr.html">58.react-ssr</a></li><li><a href="../html/59.react-ssr.html">59.react-ssr</a></li></ul></div>


<div class="warpper">

    <div class="page-toc">
        <ul><li><a href="#t01. Node.js 中有四种基本的流类型：">1. Node.js 中有四种基本的流类型：</a></li><li><a href="#t12. 流中的数据有两种模式,二进制模式和对象模式.">2. 流中的数据有两种模式,二进制模式和对象模式.</a></li><li><a href="#t23. 可读流的两种模式">3. 可读流的两种模式</a></li><li><a href="#t34.缓存区">4.缓存区</a></li><li><a href="#t45. 可读流的三种状态">5. 可读流的三种状态</a></li><li><a href="#t56.readable">6.readable</a></li><li><a href="#t67.流的经典应用">7.流的经典应用</a><ul><li><a href="#t77.1 行读取器">7.1 行读取器</a><ul><li><a href="#t87.1.1 换行和回车">7.1.1 换行和回车</a></li><li><a href="#t97.1.2 代码">7.1.2 代码</a></li></ul></li></ul></li></ul>
    </div>
    
    <div class="content markdown-body">
        <h2 id="t01. Node.js &#x4E2D;&#x6709;&#x56DB;&#x79CD;&#x57FA;&#x672C;&#x7684;&#x6D41;&#x7C7B;&#x578B;&#xFF1A;">1. Node.js &#x4E2D;&#x6709;&#x56DB;&#x79CD;&#x57FA;&#x672C;&#x7684;&#x6D41;&#x7C7B;&#x578B;&#xFF1A; <a href="#t01. Node.js &#x4E2D;&#x6709;&#x56DB;&#x79CD;&#x57FA;&#x672C;&#x7684;&#x6D41;&#x7C7B;&#x578B;&#xFF1A;"> # </a></h2>
<ul>
<li>Readable - &#x53EF;&#x8BFB;&#x7684;&#x6D41; (&#x4F8B;&#x5982; fs.createReadStream()).</li>
<li>Writable - &#x53EF;&#x5199;&#x7684;&#x6D41; (&#x4F8B;&#x5982; fs.createWriteStream()).</li>
<li>Duplex - &#x53EF;&#x8BFB;&#x5199;&#x7684;&#x6D41; (&#x4F8B;&#x5982; net.Socket).</li>
<li>Transform - &#x5728;&#x8BFB;&#x5199;&#x8FC7;&#x7A0B;&#x4E2D;&#x53EF;&#x4EE5;&#x4FEE;&#x6539;&#x548C;&#x53D8;&#x6362;&#x6570;&#x636E;&#x7684; Duplex &#x6D41; (&#x4F8B;&#x5982; zlib.createDeflate()).</li>
</ul>
<h2 id="t12. &#x6D41;&#x4E2D;&#x7684;&#x6570;&#x636E;&#x6709;&#x4E24;&#x79CD;&#x6A21;&#x5F0F;,&#x4E8C;&#x8FDB;&#x5236;&#x6A21;&#x5F0F;&#x548C;&#x5BF9;&#x8C61;&#x6A21;&#x5F0F;.">2. &#x6D41;&#x4E2D;&#x7684;&#x6570;&#x636E;&#x6709;&#x4E24;&#x79CD;&#x6A21;&#x5F0F;,&#x4E8C;&#x8FDB;&#x5236;&#x6A21;&#x5F0F;&#x548C;&#x5BF9;&#x8C61;&#x6A21;&#x5F0F;. <a href="#t12. &#x6D41;&#x4E2D;&#x7684;&#x6570;&#x636E;&#x6709;&#x4E24;&#x79CD;&#x6A21;&#x5F0F;,&#x4E8C;&#x8FDB;&#x5236;&#x6A21;&#x5F0F;&#x548C;&#x5BF9;&#x8C61;&#x6A21;&#x5F0F;."> # </a></h2>
<ul>
<li>&#x4E8C;&#x8FDB;&#x5236;&#x6A21;&#x5F0F;, &#x6BCF;&#x4E2A;&#x5206;&#x5757;&#x90FD;&#x662F;buffer&#x6216;&#x8005;string&#x5BF9;&#x8C61;.</li>
<li>&#x5BF9;&#x8C61;&#x6A21;&#x5F0F;, &#x6D41;&#x5185;&#x90E8;&#x5904;&#x7406;&#x7684;&#x662F;&#x4E00;&#x7CFB;&#x5217;&#x666E;&#x901A;&#x5BF9;&#x8C61;.<blockquote>
<p>&#x6240;&#x6709;&#x4F7F;&#x7528; Node.js API &#x521B;&#x5EFA;&#x7684;&#x6D41;&#x5BF9;&#x8C61;&#x90FD;&#x53EA;&#x80FD;&#x64CD;&#x4F5C; strings &#x548C; Buffer&#x5BF9;&#x8C61;&#x3002;&#x4F46;&#x662F;&#xFF0C;&#x901A;&#x8FC7;&#x4E00;&#x4E9B;&#x7B2C;&#x4E09;&#x65B9;&#x6D41;&#x7684;&#x5B9E;&#x73B0;&#xFF0C;&#x4F60;&#x4F9D;&#x7136;&#x80FD;&#x591F;&#x5904;&#x7406;&#x5176;&#x5B83;&#x7C7B;&#x578B;&#x7684; JavaScript &#x503C; (&#x9664;&#x4E86; null&#xFF0C;&#x5B83;&#x5728;&#x6D41;&#x5904;&#x7406;&#x4E2D;&#x6709;&#x7279;&#x6B8A;&#x610F;&#x4E49;)&#x3002; &#x8FD9;&#x4E9B;&#x6D41;&#x88AB;&#x8BA4;&#x4E3A;&#x662F;&#x5DE5;&#x4F5C;&#x5728; &#x201C;&#x5BF9;&#x8C61;&#x6A21;&#x5F0F;&#x201D;&#xFF08;object mode&#xFF09;&#x3002;
&#x5728;&#x521B;&#x5EFA;&#x6D41;&#x7684;&#x5B9E;&#x4F8B;&#x65F6;&#xFF0C;&#x53EF;&#x4EE5;&#x901A;&#x8FC7; objectMode &#x9009;&#x9879;&#x4F7F;&#x6D41;&#x7684;&#x5B9E;&#x4F8B;&#x5207;&#x6362;&#x5230;&#x5BF9;&#x8C61;&#x6A21;&#x5F0F;&#x3002;&#x8BD5;&#x56FE;&#x5C06;&#x5DF2;&#x7ECF;&#x5B58;&#x5728;&#x7684;&#x6D41;&#x5207;&#x6362;&#x5230;&#x5BF9;&#x8C61;&#x6A21;&#x5F0F;&#x662F;&#x4E0D;&#x5B89;&#x5168;&#x7684;&#x3002;</p>
</blockquote>
</li>
</ul>
<h2 id="t23. &#x53EF;&#x8BFB;&#x6D41;&#x7684;&#x4E24;&#x79CD;&#x6A21;&#x5F0F;">3. &#x53EF;&#x8BFB;&#x6D41;&#x7684;&#x4E24;&#x79CD;&#x6A21;&#x5F0F; <a href="#t23. &#x53EF;&#x8BFB;&#x6D41;&#x7684;&#x4E24;&#x79CD;&#x6A21;&#x5F0F;"> # </a></h2>
<ul>
<li>&#x53EF;&#x8BFB;&#x6D41;&#x4E8B;&#x5B9E;&#x4E0A;&#x5DE5;&#x4F5C;&#x5728;&#x4E0B;&#x9762;&#x4E24;&#x79CD;&#x6A21;&#x5F0F;&#x4E4B;&#x4E00;&#xFF1A;<code>flowing</code> &#x548C; <code>paused</code></li>
<li>&#x5728; flowing &#x6A21;&#x5F0F;&#x4E0B;&#xFF0C; &#x53EF;&#x8BFB;&#x6D41;&#x81EA;&#x52A8;&#x4ECE;&#x7CFB;&#x7EDF;&#x5E95;&#x5C42;&#x8BFB;&#x53D6;&#x6570;&#x636E;&#xFF0C;&#x5E76;&#x901A;&#x8FC7; EventEmitter &#x63A5;&#x53E3;&#x7684;&#x4E8B;&#x4EF6;&#x5C3D;&#x5FEB;&#x5C06;&#x6570;&#x636E;&#x63D0;&#x4F9B;&#x7ED9;&#x5E94;&#x7528;&#x3002;</li>
<li>&#x5728; paused &#x6A21;&#x5F0F;&#x4E0B;&#xFF0C;&#x5FC5;&#x987B;&#x663E;&#x5F0F;&#x8C03;&#x7528; stream.read() &#x65B9;&#x6CD5;&#x6765;&#x4ECE;&#x6D41;&#x4E2D;&#x8BFB;&#x53D6;&#x6570;&#x636E;&#x7247;&#x6BB5;&#x3002;</li>
<li>&#x6240;&#x6709;&#x521D;&#x59CB;&#x5DE5;&#x4F5C;&#x6A21;&#x5F0F;&#x4E3A; paused &#x7684; Readable &#x6D41;&#xFF0C;&#x53EF;&#x4EE5;&#x901A;&#x8FC7;&#x4E0B;&#x9762;&#x4E09;&#x79CD;&#x9014;&#x5F84;&#x5207;&#x6362;&#x5230; flowing &#x6A21;&#x5F0F;&#xFF1A;<ul>
<li>&#x76D1;&#x542C; &apos;data&apos; &#x4E8B;&#x4EF6;</li>
<li>&#x8C03;&#x7528; stream.resume() &#x65B9;&#x6CD5;</li>
<li>&#x8C03;&#x7528; stream.pipe() &#x65B9;&#x6CD5;&#x5C06;&#x6570;&#x636E;&#x53D1;&#x9001;&#x5230; Writable</li>
</ul>
</li>
<li>&#x53EF;&#x8BFB;&#x6D41;&#x53EF;&#x4EE5;&#x901A;&#x8FC7;&#x4E0B;&#x9762;&#x9014;&#x5F84;&#x5207;&#x6362;&#x5230; paused &#x6A21;&#x5F0F;&#xFF1A;<ul>
<li>&#x5982;&#x679C;&#x4E0D;&#x5B58;&#x5728;&#x7BA1;&#x9053;&#x76EE;&#x6807;&#xFF08;pipe destination&#xFF09;&#xFF0C;&#x53EF;&#x4EE5;&#x901A;&#x8FC7;&#x8C03;&#x7528; stream.pause() &#x65B9;&#x6CD5;&#x5B9E;&#x73B0;&#x3002;</li>
<li>&#x5982;&#x679C;&#x5B58;&#x5728;&#x7BA1;&#x9053;&#x76EE;&#x6807;&#xFF0C;&#x53EF;&#x4EE5;&#x901A;&#x8FC7;&#x53D6;&#x6D88; &apos;data&apos; &#x4E8B;&#x4EF6;&#x76D1;&#x542C;&#xFF0C;&#x5E76;&#x8C03;&#x7528; stream.unpipe() &#x65B9;&#x6CD5;&#x79FB;&#x9664;&#x6240;&#x6709;&#x7BA1;&#x9053;&#x76EE;&#x6807;&#x6765;&#x5B9E;&#x73B0;&#x3002;</li>
</ul>
</li>
</ul>
<blockquote>
<p>&#x5982;&#x679C; Readable &#x5207;&#x6362;&#x5230; flowing &#x6A21;&#x5F0F;&#xFF0C;&#x4E14;&#x6CA1;&#x6709;&#x6D88;&#x8D39;&#x8005;&#x5904;&#x7406;&#x6D41;&#x4E2D;&#x7684;&#x6570;&#x636E;&#xFF0C;&#x8FD9;&#x4E9B;&#x6570;&#x636E;&#x5C06;&#x4F1A;&#x4E22;&#x5931;&#x3002; &#x6BD4;&#x5982;&#xFF0C; &#x8C03;&#x7528;&#x4E86; readable.resume() &#x65B9;&#x6CD5;&#x5374;&#x6CA1;&#x6709;&#x76D1;&#x542C; &apos;data&apos; &#x4E8B;&#x4EF6;&#xFF0C;&#x6216;&#x662F;&#x53D6;&#x6D88;&#x4E86; &apos;data&apos; &#x4E8B;&#x4EF6;&#x76D1;&#x542C;&#xFF0C;&#x5C31;&#x6709;&#x53EF;&#x80FD;&#x51FA;&#x73B0;&#x8FD9;&#x79CD;&#x60C5;&#x51B5;&#x3002;</p>
</blockquote>
<h2 id="t34.&#x7F13;&#x5B58;&#x533A;">4.&#x7F13;&#x5B58;&#x533A; <a href="#t34.&#x7F13;&#x5B58;&#x533A;"> # </a></h2>
<ul>
<li><p>Writable &#x548C; Readable &#x6D41;&#x90FD;&#x4F1A;&#x5C06;&#x6570;&#x636E;&#x5B58;&#x50A8;&#x5230;&#x5185;&#x90E8;&#x7684;&#x7F13;&#x51B2;&#x5668;&#xFF08;buffer&#xFF09;&#x4E2D;&#x3002;&#x8FD9;&#x4E9B;&#x7F13;&#x51B2;&#x5668;&#x53EF;&#x4EE5; &#x901A;&#x8FC7;&#x76F8;&#x5E94;&#x7684; writable._writableState.getBuffer() &#x6216; readable._readableState.buffer &#x6765;&#x83B7;&#x53D6;&#x3002;</p>
</li>
<li><p>&#x7F13;&#x51B2;&#x5668;&#x7684;&#x5927;&#x5C0F;&#x53D6;&#x51B3;&#x4E8E;&#x4F20;&#x9012;&#x7ED9;&#x6D41;&#x6784;&#x9020;&#x51FD;&#x6570;&#x7684; highWaterMark &#x9009;&#x9879;&#x3002; &#x5BF9;&#x4E8E;&#x666E;&#x901A;&#x7684;&#x6D41;&#xFF0C; highWaterMark &#x9009;&#x9879;&#x6307;&#x5B9A;&#x4E86;&#x603B;&#x5171;&#x7684;&#x5B57;&#x8282;&#x6570;&#x3002;&#x5BF9;&#x4E8E;&#x5DE5;&#x4F5C;&#x5728;&#x5BF9;&#x8C61;&#x6A21;&#x5F0F;&#x7684;&#x6D41;&#xFF0C; highWaterMark &#x6307;&#x5B9A;&#x4E86;&#x5BF9;&#x8C61;&#x7684;&#x603B;&#x6570;&#x3002;</p>
</li>
<li><p>&#x5F53;&#x53EF;&#x8BFB;&#x6D41;&#x7684;&#x5B9E;&#x73B0;&#x8C03;&#x7528;<code>stream.push(chunk)</code>&#x65B9;&#x6CD5;&#x65F6;&#xFF0C;&#x6570;&#x636E;&#x88AB;&#x653E;&#x5230;&#x7F13;&#x51B2;&#x5668;&#x4E2D;&#x3002;&#x5982;&#x679C;&#x6D41;&#x7684;&#x6D88;&#x8D39;&#x8005;&#x6CA1;&#x6709;&#x8C03;&#x7528;<code>stream.read()</code>&#x65B9;&#x6CD5;&#xFF0C; &#x8FD9;&#x4E9B;&#x6570;&#x636E;&#x4F1A;&#x59CB;&#x7EC8;&#x5B58;&#x5728;&#x4E8E;&#x5185;&#x90E8;&#x961F;&#x5217;&#x4E2D;&#xFF0C;&#x76F4;&#x5230;&#x88AB;&#x6D88;&#x8D39;&#x3002;</p>
</li>
<li><p>&#x5F53;&#x5185;&#x90E8;&#x53EF;&#x8BFB;&#x7F13;&#x51B2;&#x5668;&#x7684;&#x5927;&#x5C0F;&#x8FBE;&#x5230; highWaterMark &#x6307;&#x5B9A;&#x7684;&#x9608;&#x503C;&#x65F6;&#xFF0C;&#x6D41;&#x4F1A;&#x6682;&#x505C;&#x4ECE;&#x5E95;&#x5C42;&#x8D44;&#x6E90;&#x8BFB;&#x53D6;&#x6570;&#x636E;&#xFF0C;&#x76F4;&#x5230;&#x5F53;&#x524D; &#x7F13;&#x51B2;&#x5668;&#x7684;&#x6570;&#x636E;&#x88AB;&#x6D88;&#x8D39; (&#x4E5F;&#x5C31;&#x662F;&#x8BF4;&#xFF0C; &#x6D41;&#x4F1A;&#x5728;&#x5185;&#x90E8;&#x505C;&#x6B62;&#x8C03;&#x7528; readable._read() &#x6765;&#x586B;&#x5145;&#x53EF;&#x8BFB;&#x7F13;&#x51B2;&#x5668;)&#x3002;</p>
</li>
<li><p>&#x53EF;&#x5199;&#x6D41;&#x901A;&#x8FC7;&#x53CD;&#x590D;&#x8C03;&#x7528; writable.write(chunk) &#x65B9;&#x6CD5;&#x5C06;&#x6570;&#x636E;&#x653E;&#x5230;&#x7F13;&#x51B2;&#x5668;&#x3002; &#x5F53;&#x5185;&#x90E8;&#x53EF;&#x5199;&#x7F13;&#x51B2;&#x5668;&#x7684;&#x603B;&#x5927;&#x5C0F;&#x5C0F;&#x4E8E; highWaterMark &#x6307;&#x5B9A;&#x7684;&#x9608;&#x503C;&#x65F6;&#xFF0C; &#x8C03;&#x7528; writable.write() &#x5C06;&#x8FD4;&#x56DE;true&#x3002; &#x4E00;&#x65E6;&#x5185;&#x90E8;&#x7F13;&#x51B2;&#x5668;&#x7684;&#x5927;&#x5C0F;&#x8FBE;&#x5230;&#x6216;&#x8D85;&#x8FC7; highWaterMark &#xFF0C;&#x8C03;&#x7528; writable.write() &#x5C06;&#x8FD4;&#x56DE; false &#x3002;</p>
</li>
<li><p>stream API &#x7684;&#x5173;&#x952E;&#x76EE;&#x6807;&#xFF0C; &#x5C24;&#x5176;&#x5BF9;&#x4E8E; stream.pipe() &#x65B9;&#x6CD5;&#xFF0C; &#x5C31;&#x662F;&#x9650;&#x5236;&#x7F13;&#x51B2;&#x5668;&#x6570;&#x636E;&#x5927;&#x5C0F;&#xFF0C;&#x4EE5;&#x8FBE;&#x5230;&#x53EF;&#x63A5;&#x53D7;&#x7684;&#x7A0B;&#x5EA6;&#x3002;&#x8FD9;&#x6837;&#xFF0C;&#x5BF9;&#x4E8E;&#x8BFB;&#x5199;&#x901F;&#x5EA6;&#x4E0D;&#x5339;&#x914D;&#x7684;&#x6E90;&#x5934;&#x548C;&#x76EE;&#x6807;&#xFF0C;&#x5C31;&#x4E0D;&#x4F1A;&#x8D85;&#x51FA;&#x53EF;&#x7528;&#x7684;&#x5185;&#x5B58;&#x5927;&#x5C0F;&#x3002;</p>
</li>
<li><p>Duplex &#x548C; Transform &#x90FD;&#x662F;&#x53EF;&#x8BFB;&#x5199;&#x7684;&#x3002; &#x5728;&#x5185;&#x90E8;&#xFF0C;&#x5B83;&#x4EEC;&#x90FD;&#x7EF4;&#x62A4;&#x4E86; &#x4E24;&#x4E2A; &#x76F8;&#x4E92;&#x72EC;&#x7ACB;&#x7684;&#x7F13;&#x51B2;&#x5668;&#x7528;&#x4E8E;&#x8BFB;&#x548C;&#x5199;&#x3002; &#x5728;&#x7EF4;&#x6301;&#x4E86;&#x5408;&#x7406;&#x9AD8;&#x6548;&#x7684;&#x6570;&#x636E;&#x6D41;&#x7684;&#x540C;&#x65F6;&#xFF0C;&#x4E5F;&#x4F7F;&#x5F97;&#x5BF9;&#x4E8E;&#x8BFB;&#x548C;&#x5199;&#x53EF;&#x4EE5;&#x72EC;&#x7ACB;&#x8FDB;&#x884C;&#x800C;&#x4E92;&#x4E0D;&#x5F71;&#x54CD;&#x3002;</p>
</li>
</ul>
<h2 id="t45. &#x53EF;&#x8BFB;&#x6D41;&#x7684;&#x4E09;&#x79CD;&#x72B6;&#x6001;">5. &#x53EF;&#x8BFB;&#x6D41;&#x7684;&#x4E09;&#x79CD;&#x72B6;&#x6001; <a href="#t45. &#x53EF;&#x8BFB;&#x6D41;&#x7684;&#x4E09;&#x79CD;&#x72B6;&#x6001;"> # </a></h2>
<p>&#x5728;&#x4EFB;&#x610F;&#x65F6;&#x523B;&#xFF0C;&#x4EFB;&#x610F;&#x53EF;&#x8BFB;&#x6D41;&#x5E94;&#x786E;&#x5207;&#x5904;&#x4E8E;&#x4E0B;&#x9762;&#x4E09;&#x79CD;&#x72B6;&#x6001;&#x4E4B;&#x4E00;&#xFF1A;</p>
<ul>
<li>readable._readableState.flowing = null</li>
<li>readable._readableState.flowing = false</li>
<li><p>readable._readableState.flowing = true</p>
</li>
<li><p>&#x82E5; readable._readableState.flowing &#x4E3A; null&#xFF0C;&#x7531;&#x4E8E;&#x4E0D;&#x5B58;&#x5728;&#x6570;&#x636E;&#x6D88;&#x8D39;&#x8005;&#xFF0C;&#x53EF;&#x8BFB;&#x6D41;&#x5C06;&#x4E0D;&#x4F1A;&#x4EA7;&#x751F;&#x6570;&#x636E;&#x3002; &#x5728;&#x8FD9;&#x4E2A;&#x72B6;&#x6001;&#x4E0B;&#xFF0C;&#x76D1;&#x542C; &apos;data&apos; &#x4E8B;&#x4EF6;&#xFF0C;&#x8C03;&#x7528; readable.pipe() &#x65B9;&#x6CD5;&#xFF0C;&#x6216;&#x8005;&#x8C03;&#x7528; readable.resume() &#x65B9;&#x6CD5;&#xFF0C; readable._readableState.flowing &#x7684;&#x503C;&#x5C06;&#x4F1A;&#x53D8;&#x4E3A; true &#x3002;&#x8FD9;&#x65F6;&#xFF0C;&#x968F;&#x7740;&#x6570;&#x636E;&#x751F;&#x6210;&#xFF0C;&#x53EF;&#x8BFB;&#x6D41;&#x5F00;&#x59CB;&#x9891;&#x7E41;&#x89E6;&#x53D1;&#x4E8B;&#x4EF6;&#x3002;</p>
</li>
<li><p>&#x8C03;&#x7528; readable.pause() &#x65B9;&#x6CD5;&#xFF0C; readable.unpipe() &#x65B9;&#x6CD5;&#xFF0C; &#x6216;&#x8005;&#x63A5;&#x6536; &#x201C;&#x80CC;&#x538B;&#x201D;&#xFF08;back pressure&#xFF09;&#xFF0C; &#x5C06;&#x5BFC;&#x81F4; readable._readableState.flowing &#x503C;&#x53D8;&#x4E3A; false&#x3002; &#x8FD9;&#x5C06;&#x6682;&#x505C;&#x4E8B;&#x4EF6;&#x6D41;&#xFF0C;&#x4F46; &#x4E0D;&#x4F1A; &#x6682;&#x505C;&#x6570;&#x636E;&#x751F;&#x6210;&#x3002; &#x5728;&#x8FD9;&#x79CD;&#x60C5;&#x51B5;&#x4E0B;&#xFF0C;&#x4E3A; &apos;data&apos; &#x4E8B;&#x4EF6;&#x8BBE;&#x7F6E;&#x76D1;&#x542C;&#x51FD;&#x6570;&#x4E0D;&#x4F1A;&#x5BFC;&#x81F4; readable._readableState.flowing &#x53D8;&#x4E3A; true&#x3002;</p>
</li>
<li><p>&#x5F53; readable._readableState.flowing &#x503C;&#x4E3A; false &#x65F6;&#xFF0C; &#x6570;&#x636E;&#x53EF;&#x80FD;&#x5806;&#x79EF;&#x5230;&#x6D41;&#x7684;&#x5185;&#x90E8;&#x7F13;&#x5B58;&#x4E2D;&#x3002;</p>
</li>
</ul>
<h2 id="t56.readable">6.readable <a href="#t56.readable"> # </a></h2>
<p>&apos;readable&apos; &#x4E8B;&#x4EF6;&#x5C06;&#x5728;&#x6D41;&#x4E2D;&#x6709;&#x6570;&#x636E;&#x53EF;&#x4F9B;&#x8BFB;&#x53D6;&#x65F6;&#x89E6;&#x53D1;&#x3002;&#x5728;&#x67D0;&#x4E9B;&#x60C5;&#x51B5;&#x4E0B;&#xFF0C;&#x4E3A; &apos;readable&apos; &#x4E8B;&#x4EF6;&#x6DFB;&#x52A0;&#x56DE;&#x8C03;&#x5C06;&#x4F1A;&#x5BFC;&#x81F4;&#x4E00;&#x4E9B;&#x6570;&#x636E;&#x88AB;&#x8BFB;&#x53D6;&#x5230;&#x5185;&#x90E8;&#x7F13;&#x5B58;&#x4E2D;&#x3002;</p>
<pre><code>const readable = getReadableStreamSomehow();
readable.on(&apos;readable&apos;, () =&gt; {
  // &#x6709;&#x4E00;&#x4E9B;&#x6570;&#x636E;&#x53EF;&#x8BFB;&#x4E86;
});
</code></pre><ul>
<li>&#x5F53;&#x5230;&#x8FBE;&#x6D41;&#x6570;&#x636E;&#x5C3E;&#x90E8;&#x65F6;&#xFF0C; &apos;readable&apos; &#x4E8B;&#x4EF6;&#x4E5F;&#x4F1A;&#x89E6;&#x53D1;&#x3002;&#x89E6;&#x53D1;&#x987A;&#x5E8F;&#x5728; &apos;end&apos; &#x4E8B;&#x4EF6;&#x4E4B;&#x524D;&#x3002;</li>
<li>&#x4E8B;&#x5B9E;&#x4E0A;&#xFF0C; &apos;readable&apos; &#x4E8B;&#x4EF6;&#x8868;&#x660E;&#x6D41;&#x6709;&#x4E86;&#x65B0;&#x7684;&#x52A8;&#x6001;&#xFF1A;&#x8981;&#x4E48;&#x662F;&#x6709;&#x4E86;&#x65B0;&#x7684;&#x6570;&#x636E;&#xFF0C;&#x8981;&#x4E48;&#x662F;&#x5230;&#x4E86;&#x6D41;&#x7684;&#x5C3E;&#x90E8;&#x3002; &#x5BF9;&#x4E8E;&#x524D;&#x8005;&#xFF0C; stream.read() &#x5C06;&#x8FD4;&#x56DE;&#x53EF;&#x7528;&#x7684;&#x6570;&#x636E;&#x3002;&#x800C;&#x5BF9;&#x4E8E;&#x540E;&#x8005;&#xFF0C; stream.read() &#x5C06;&#x8FD4;&#x56DE; null&#x3002;</li>
</ul>
<pre><code>let fs =require(&apos;fs&apos;);
let rs = fs.createReadStream(&apos;./1.txt&apos;,{
  start:3,
  end:8,
  encoding:&apos;utf8&apos;,
  highWaterMark:3
});
rs.on(&apos;readable&apos;,function () {
  console.log(&apos;readable&apos;);
  console.log(&apos;rs._readableState.buffer.length&apos;,rs._readableState.length);
  let d = rs.read(1);
  console.log(&apos;rs._readableState.buffer.length&apos;,rs._readableState.length);
  console.log(d);
  setTimeout(()=&gt;{
      console.log(&apos;rs._readableState.buffer.length&apos;,rs._readableState.length);
  },500)
});
</code></pre><h2 id="t67.&#x6D41;&#x7684;&#x7ECF;&#x5178;&#x5E94;&#x7528;">7.&#x6D41;&#x7684;&#x7ECF;&#x5178;&#x5E94;&#x7528; <a href="#t67.&#x6D41;&#x7684;&#x7ECF;&#x5178;&#x5E94;&#x7528;"> # </a></h2>
<h3 id="t77.1 &#x884C;&#x8BFB;&#x53D6;&#x5668;">7.1 &#x884C;&#x8BFB;&#x53D6;&#x5668; <a href="#t77.1 &#x884C;&#x8BFB;&#x53D6;&#x5668;"> # </a></h3>
<h4 id="t87.1.1 &#x6362;&#x884C;&#x548C;&#x56DE;&#x8F66;">7.1.1 &#x6362;&#x884C;&#x548C;&#x56DE;&#x8F66; <a href="#t87.1.1 &#x6362;&#x884C;&#x548C;&#x56DE;&#x8F66;"> # </a></h4>
<ul>
<li>&#x4EE5;&#x524D;&#x7684;&#x6253;&#x5370;&#x8981;&#x6BCF;&#x79D2;&#x53EF;&#x4EE5;&#x6253;&#x5370;10&#x4E2A;&#x5B57;&#x7B26;&#xFF0C;&#x6362;&#x884C;&#x57CE;&#x8981;0.2&#x79D2;&#xFF0C;&#x6B63;&#x8981;&#x53EF;&#x4EE5;&#x6253;&#x5370;2&#x4E2A;&#x5B57;&#x7B26;&#x3002;</li>
<li>&#x7814;&#x5236;&#x4EBA;&#x5458;&#x5C31;&#x662F;&#x5728;&#x6BCF;&#x884C;&#x540E;&#x9762;&#x52A0;&#x4E24;&#x4E2A;&#x8868;&#x793A;&#x7ED3;&#x675F;&#x7684;&#x5B57;&#x7B26;&#x3002;&#x4E00;&#x4E2A;&#x53EB;&#x505A;&quot;&#x56DE;&#x8F66;&quot;&#xFF0C;&#x544A;&#x8BC9;&#x6253;&#x5B57;&#x673A;&#x628A;&#x6253;&#x5370;&#x5934;&#x5B9A;&#x4F4D;&#x5728;&#x5DE6;&#x8FB9;&#x754C;&#xFF1B;&#x53E6;&#x4E00;&#x4E2A;&#x53EB;&#x505A;&quot;&#x6362;&#x884C;&quot;&#xFF0C;&#x544A;&#x8BC9;&#x6253;&#x5B57;&#x673A;&#x628A;&#x7EB8;&#x5411;&#x4E0B;&#x79FB;&#x4E00;&#x884C;&#x3002;</li>
<li>Unix&#x7CFB;&#x7EDF;&#x91CC;&#xFF0C;&#x6BCF;&#x884C;&#x7ED3;&#x5C3E;&#x53EA;&#x6709;&#x6362;&#x884C;&quot;(line feed)&quot;&#xFF0C;&#x5373;&quot;\n&quot;,</li>
<li>Windows&#x7CFB;&#x7EDF;&#x91CC;&#x9762;&#xFF0C;&#x6BCF;&#x884C;&#x7ED3;&#x5C3E;&#x662F;&quot;&lt;&#x56DE;&#x8F66;&gt;&lt;&#x6362;&#x884C;&gt;&quot;&#xFF0C;&#x5373;&quot;\r\n&quot;</li>
<li>Mac&#x7CFB;&#x7EDF;&#x91CC;&#xFF0C;&#x6BCF;&#x884C;&#x7ED3;&#x5C3E;&#x662F;&quot;&#x56DE;&#x8F66;&quot;(carriage return)&#xFF0C;&#x5373;&quot;\r&quot;</li>
<li>&#x5728;ASCII&#x7801;&#x91CC;<ul>
<li>&#x6362;&#x884C; \n  10 0A</li>
<li>&#x56DE;&#x8F66; \r  13 0D</li>
</ul>
</li>
</ul>
<p><a href="http://ascii.911cha.com/">ASCII</a></p>
<h4 id="t97.1.2 &#x4EE3;&#x7801;">7.1.2 &#x4EE3;&#x7801; <a href="#t97.1.2 &#x4EE3;&#x7801;"> # </a></h4>
<pre><code>let fs = require(&apos;fs&apos;);
let EventEmitter = require(&apos;events&apos;);
let util = require(&apos;util&apos;);
util.inherits(LineReader, EventEmitter)
fs.readFile(&apos;./1.txt&apos;,function (err,data) {
    console.log(data);
})
function LineReader(path) {
    EventEmitter.call(this);
    this._rs = fs.createReadStream(path);
    this.RETURN = 0x0D;// \r 13
    this.NEW_LINE = 0x0A;// \n 10
    this.on(&apos;newListener&apos;, function (type, listener) {
        if (type == &apos;newLine&apos;) {
            let buffer = [];
            this._rs.on(&apos;readable&apos;, () =&gt; {
                let bytes;
                while (null != (bytes = this._rs.read(1))) {
                    let ch = bytes[0];
                    switch (ch) {
                        case this.RETURN:
                            this.emit(&apos;newLine&apos;, Buffer.from(buffer));
                            buffer.length = 0;
                            let nByte = this._rs.read(1);
                            if (nByte &amp;&amp; nByte[0] != this.NEW_LINE) {
                                buffer.push(nByte[0]);
                            }
                            break;
                        case this.NEW_LINE:
                            this.emit(&apos;newLine&apos;, Buffer.from(buffer));
                            buffer.length = 0;
                            break;
                        default:
                            buffer.push(bytes[0]);
                            break;
                    }
                }
            });
            this._rs.on(&apos;end&apos;, () =&gt; {
                if (buffer.length &gt; 0) {
                    this.emit(&apos;newLine&apos;, Buffer.from(buffer));
                    buffer.length = 0;
                    this.emit(&apos;end&apos;);
                }
            })
        }
    });
}

var lineReader = new LineReader(&apos;./1.txt&apos;);
lineReader.on(&apos;newLine&apos;, function (data) {
    console.log(data.toString());
}).on(&apos;end&apos;, function () {
    console.log(&quot;end&quot;);
})


</code></pre>
        <div class="copyright">Powered by <a href="https://github.com/jaywcjlove/idoc" target="_blank">idoc</a>. Dependence <a href="https://nodejs.org">Node.js</a> run.</div>
    </div>
    
</div>

<script src="https://cdn.bootcss.com/jquery/3.0.0/jquery.js"></script>
<script>
$('.warpper .page-toc ul ul li a').on('click',function(){
  $('.warpper .page-toc ul ul li a').removeClass('my-active')
  $(this).addClass('my-active')
})
  // if (!$('.understand-me').length) {
  //   var bar = $(window).height() - $('.navbar ').height() - $('.page-toc').position().top;
  //   var count = bar / 26 / 2;
  //   var barHeight = $('.page-toc').outerHeight();
  //   $('.page-toc li').eq(0).children('a').addClass('red');
  //   var arr = [];
  //   $("h1,h2,h3,h4,h5,h6").each(function () {
  //     arr.push($(this).position().top);
  //   });
  //   var timer
  //   function dark() {
  //     clearTimeout(timer)
  //      timer = setTimeout(function () {
  //      var top = Math.abs($('.page-toc > ul').position().top);
  //      var cur = $('.content').scrollTop();
  //      for (var i = arr.length; i >= 0; i--) {
  //        if (arr[i] <= cur) {
  //          break;
  //        }
  //      }
  //      if (i === -1) {
  //        i = 0;
  //      }
  //      $('.page-toc li a').removeClass('red');
  //      $('.page-toc li').eq(i).children('a').addClass('red');
  //      let height = $('.page-toc li').eq(i).position().top-$('.page-toc').height(); // 如果当前的offset出去了 回到中间可好？
  //      $('.page-toc').scrollTop(height+$('.page-toc').height()/2);
  //    },200)
  //   }

  //   $('.content').on('scroll', dark);
  // }
</script>
<style>

    /* ::-webkit-scrollbar{width:14px;}
    ::-webkit-scrollbar-track{background-color:transparent;}
    ::-webkit-scrollbar-thumb{background-color:transparent;}
    ::-webkit-scrollbar-thumb:hover {background-color:transparent}
    ::-webkit-scrollbar-thumb:active {background-color:transparent} */

    .page-toc > ul .red {
        background: #f3f3f3;
        z-index: 1;
        border-left: 3px solid #009a61;
        -webkit-transition: all .2s ease;
        transition: all .2s ease;
        color: #000
    }





</style>
</body>
</html>
